package com.djq.project.mq.consumer.queues;

import lombok.extern.slf4j.Slf4j;
import org.springframework.amqp.rabbit.annotation.RabbitHandler;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;

/**
 * 工作模式 work queues
 */
@Slf4j
@Component
@RabbitListener(queues = "work")
public class RecvQueues2 {
    @RabbitHandler
    public void receive(String in) {
        System.out.println(" [work2] Received '" + in + "'");
    }
}
